package com.powerdata.system.paimon;

import com.powerdata.system.domain.PaimonSyncTask;
import com.powerdata.system.domain.param.PaimonSyncTaskParam;

import java.util.Map;

/**
 * @author deeprado
 * @version 1.0
 * @description
 * @date 2023/8/29 16:08
 */
public interface PaimonSyncTaskService {
    Map<String, Object> taskList(PaimonSyncTaskParam paimonSyncTaskParam) throws Exception;

    void add(PaimonSyncTask paimonSyncTask) throws Exception;

    void stopKafkaTask(PaimonSyncTask paimonSyncTask) throws Exception;

    void batchAddHiveTask(PaimonSyncTask paimonSyncTask) throws Exception;

    void batchAddMySqlTask(PaimonSyncTask paimonSyncTask) throws Exception;
}
